package com.juc.future;

import java.sql.Time;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;

/**
 * @Author Zan
 * @Create 2024/5/6 20:13
 * @ClassName : FutureAPIDemo
 * @Description : TODO 请用一句话描述该类的功能
 */
public class FutureAPIDemo {
    public static void main(String[] args) throws Exception {
        FutureTask<String> futureTask = new FutureTask<String>(() -> {
            System.out.println(Thread.currentThread().getName() + "\t -----come in");
            // 暂停几秒钟线程
            TimeUnit.SECONDS.sleep(5);
            return "task over";
        });

        Thread t1 = new Thread(futureTask, "t1");
        t1.start();

        System.out.println(Thread.currentThread().getName() + "\t ----忙其他任务了");

        // get() 会进行堵塞，一旦调用get()方法，不管是否计算完成都会导致阻塞，只有等到结果才会离开，所以一般会防到最后面
//        System.out.println(futureTask.get());
//        System.out.println(futureTask.get(1L, TimeUnit.SECONDS)); // 超过1s，就会自动离开

        while (true) {
            if (futureTask.isDone()) {
                System.out.println(futureTask.get());
                break;
            } else {
                TimeUnit.MILLISECONDS.sleep(500);
                System.out.println("正在处理中，不要再催啦，越催越慢，再催熄火");
            }
        }
    }
}
/**
 * 1.get容易导致阻塞，一般建议放在程序后面，一旦调用不见不散，非要等到结果才会离开，不管你是否计算完成，容易程序堵塞
 * 2.假如我不愿意等待很长时间，我希望过时不候，可以自动离开
 */
